package com.hehao.entity;

import org.reactivestreams.Publisher;
import reactor.core.publisher.Flux;
import reactor.core.publisher.Mono;

/**
 * @Author Damon
 * @Date 2024/5/8 17:07
 */
public class BlockingRepository<T> implements ReactiveRepository {
    @Override
    public Mono<Void> save(Publisher publisher) {
        return null;
    }

    @Override
    public Mono findFirst() {
        return null;
    }

    @Override
    public Flux findAll() {
        return null;
    }

    @Override
    public Mono findById(String id) {
        return null;
    }
}
